/*
    This sketch establishes a TCP connection to a "quote of the day" service.
    It sends a "hello" message, and then prints received data.
*/

#include <WiFi.h>

#ifndef STASSID
#define STASSID "your-ssid"
#define STAPSK "your-password"
#endif

const char* ssid = STASSID;
const char* password = STAPSK;

const char* host = "djxmmx.net";
const uint16_t port = 17;

//WiFiMulti multi;

void setup() {
  Serial.begin(115200);

  // We start by connecting to a WiFi network

  Serial.println();
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

//  multi.addAP(ssid, password);

//  if (multi.run() != WL_CONNECTED) {
    //Serial.println("Unable to connect to network, rebooting in 10 seconds...");
    //delay(10000);
    //rp2040.reboot();
  //}
delay(5000);
  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  //Serial.println(WiFi.localIP());
}

static int l = 0;static int f= 0;
void loop() {
  static bool wait = false;
  Serial.printf("++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ %d %d\n", l++, rp2040.getFreeHeap());
  //stats_display();
  WiFi.begin(ssid, password);
  if (!WiFi.connected()) {
      Serial.printf("--------------------------------------------------------------------------------- fail %d\n", f++);
      delay(1000);
    return;
  }

  Serial.print("connecting to ");
  Serial.print(host);
  Serial.print(':');
  Serial.println(port);

  // Use WiFiClient class to create TCP connections
  WiFiClient client;
  if (!client.connect(host, port)) {
    Serial.println("connection failed");
    delay(5000);
    return;
  }

  // This will send a string to the server
  Serial.println("sending data to server");
  if (client.connected()) {
    client.println("hello from RP2040");
  }

  // wait for data to be available
  unsigned long timeout = millis();
  while (client.available() == 0) {
    if (millis() - timeout > 5000) {
      Serial.println(">>> Client Timeout !");
      client.stop();
      WiFi.end();
      //delay(60000);
      return;
    }
  }

  // Read all the lines of the reply from server and print them to Serial
  Serial.println("receiving from remote server");
  // not testing 'client.connected()' since we do not need to send data here
  while (client.available()) {
    char ch = static_cast<char>(client.read());
    Serial.print(ch);
  }

  // Close the connection
  Serial.println();
  Serial.println("closing connection");
  client.stop();

  if (wait) {
//    delay(300000);  // execute once every 5 minutes, don't flood remote service
  }
  //Serial.printf("++++at end++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ %d %d\n", l, rp2040.getFreeHeap());
  //stats_display();
//delay(16000);
//  Serial.printf("++after 16s ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ %d %d\n", l, rp2040.getFreeHeap());
//  stats_display();


  //wait = true;
  WiFi.end();
//  Serial.printf("++++after wifiend++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ %d %d\n", l, rp2040.getFreeHeap());
//  stats_display();

//while(1);
}

    if (_isDHCP) {
        ip4_addr_set_u32(ip_2_ip4(&_netif.ip_addr), 0);

        netif_set_up(&_netif);
        if (netif_is_link_up(&_netif)) {
            switch (dhcp_start(&_netif)) {
            case ERR_OK:
                break;
            case ERR_IF:
                netif_remove(&_netif);
                return false;
            default:
                netif_remove(&_netif);
                return false;
            }
        }
    } else {
        netif_set_link_up(&_netif);
        netif_set_up(&_netif);
    }

void LwipIntfDev<RawDev>::end() {
    if (_started) {
        if (_intrPin < 0) {
            __removeEthernetPacketHandler(_phID);
        } else {
            detachInterrupt(_intrPin);
            __removeEthernetGPIO(_intrPin);
        }

        if (_removeNetifCB) {
            _removeNetifCB(&_netif);
        }

        RawDev::end();
	
        if (_isDHCP) {
            dhcp_stop(&_netif);
            dhcp_cleanup(&_netif);
        }

        netif_remove(&_netif);

        _started = false;
    }
}

        uint32_t fdebug_tx_stall = 1u << (PIO_FDEBUG_TXSTALL_LSB + bus_data->pio_sm);
        bus_data->pio->fdebug = fdebug_tx_stall;

	//! timeout !
        uint32_t start_time = time_us_32();
        uint32_t timeout_us = 1000;
        while (!(bus_data->pio->fdebug & fdebug_tx_stall)) {
            if (time_us_32() - start_time > timeout_us) {
                pio_error = 1;
                break; 
            }
            tight_loop_contents();
        }

        __compiler_memory_barrier();
        pio_sm_set_enabled(bus_data->pio, bus_data->pio_sm, false);
        pio_sm_set_consecutive_pindirs(bus_data->pio, bus_data->pio_sm, CYW43_PIN_WL_DATA_IN, 1, false);
    } else if (rx != NULL) { /* currently do one at a time */
        DUMP_SPI_TRANSACTIONS(
                printf("[%lu] bus TX %u bytes:", counter++, rx_length);
                dump_bytes(rx, rx_length);
        )
        panic_unsupported();
    }
    pio_sm_exec(bus_data->pio, bus_data->pio_sm, pio_encode_mov(pio_pins, pio_null)); // for next time we turn output on

    stop_spi_comms();
    DUMP_SPI_TRANSACTIONS(
            printf("RXed:");
            dump_bytes(rx, rx_length);
            printf("\n");
    )

    //! pio error !
    if (pio_error > 0){
        return CYW43_EIO;
    }

    return 0;
}